package concurrent;


public class Main {

    public static void main(String[] args) {
        MxQueueBuffer buffer = new MxQueueBuffer();
        new MxProducer(buffer);
        new MxConsumer(buffer);
        System.out.println("Press Control-C to stop.");
    }
}